RabbitMQMessageAdapter

class RabbitMQMessageAdapter(val rabbitMQHost: String = "localhost", val rabbitMQPort: Int = 5672, val rabbitMQUsername: String = "guest", val rabbitMQPassword: String = "guest", serializer: EventSerializer) : MessageAdapter

A message adapter for RabbitMQ to handle posting events and managing connections.

Constructors

Link copied to clipboard
constructor(rabbitMQHost: String = "localhost", rabbitMQPort: Int = 5672, rabbitMQUsername: String = "guest", rabbitMQPassword: String = "guest", serializer: EventSerializer)

Properties

Link copied to clipboard

The RabbitMQ host address.

Link copied to clipboard

The RabbitMQ password.

Link copied to clipboard
val rabbitMQPort: Int = 5672

The RabbitMQ port number.

Link copied to clipboard

The RabbitMQ username.

Functions

Link copied to clipboard
open override fun close()

Closes the RabbitMQ channel and connection.

Link copied to clipboard
open override fun postEvent(type: EventType, event: Event)

Posts an event to the RabbitMQ exchange.